type google.golang.org/grpc/internal/transport.serverHandlerTransport
16 uses
google.golang.org/grpc/internal/transport (current package)
handler_server.go#L92: st := &serverHandlerTransport{
handler_server.go#L145: type serverHandlerTransport struct {
handler_server.go#L179: func (ht *serverHandlerTransport) Close(err error) {
handler_server.go#L188: func (ht *serverHandlerTransport) Peer() *peer.Peer {
handler_server.go#L219: func (ht *serverHandlerTransport) do(fn func()) error {
handler_server.go#L228: func (ht *serverHandlerTransport) writeStatus(s *ServerStream, st *status.Status) error {
handler_server.go#L294: func (ht *serverHandlerTransport) writePendingHeaders(s *ServerStream) {
handler_server.go#L301: func (ht *serverHandlerTransport) writeCommonHeaders(s *ServerStream) {
handler_server.go#L322: func (ht *serverHandlerTransport) writeCustomHeaders(s *ServerStream) {
handler_server.go#L338: func (ht *serverHandlerTransport) write(s *ServerStream, hdr []byte, data mem.BufferSlice, _ *WriteOptions) error {
handler_server.go#L362: func (ht *serverHandlerTransport) writeHeader(s *ServerStream, md metadata.MD) error {
handler_server.go#L390: func (ht *serverHandlerTransport) HandleStreams(ctx context.Context, startStream func(*ServerStream)) {
handler_server.go#L467: func (ht *serverHandlerTransport) runStream() {
handler_server.go#L478: func (ht *serverHandlerTransport) incrMsgRecv() {}
handler_server.go#L480: func (ht *serverHandlerTransport) Drain(string) {
logging.go#L34: func prefixLoggerForServerHandlerTransport(p *serverHandlerTransport) *internalgrpclog.PrefixLogger {
The pages are generated with Golds v0.7.6. (GOOS=linux GOARCH=amd64)